package com.cande.loki.exercise.disruptor;

import com.lmax.disruptor.EventHandler;
import com.lmax.disruptor.WorkHandler;

/**
 * @Description 事件消费者
 * @Author wgf
 * @Date 2022/8/22 2:31 PM
 */
public class LongEventWorkHandler implements WorkHandler<LongEvent> {

    @Override
    public void onEvent(LongEvent longEvent) throws Exception {
        System.out.println(Thread.currentThread().getName() + ":" + longEvent.getValue());
    }
}
